package com.springboot.kafka.message.base;

import java.io.Serializable;
import java.util.Date;
import lombok.Data;

/**
 * kafka消息体
 *
 * @author supu
 * @create 2019-01-28 17:16
 **/
@Data
public class KafkaMessage<T extends Body> implements Serializable {
    private static final long serialVersionUID = -5082973649267141267L;

    /**
     * 消息类型
     */
    private String messageType;

    /**
     * 消息创建时间
     */
    private Date createTime = new Date();

    /**
     * 消息体
     */
    private T body;
}
